﻿using LJ.EventBus.FastDog.Transport.Abstractions;
using Microsoft.Extensions.Logging;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace LJ.EventBus.FastDog.Transport.InMemoryQueue.Internal;


internal sealed class InMemoryQueueConsumerClientFactory(MemoryQueue memoryQueue) : IConsumerClientFactory
{
    private readonly MemoryQueue _memoryQueue = memoryQueue;
    public IConsumerClient Create(string groupId)
    {
        return new InMemoryQueueConsumerClient(_memoryQueue, groupId);
    }
}